package org.niit.controller

import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.Answer
import org.niit.service.{EDUDataService, EDURecommendService}

/**
 * Date:2025/6/11
 * Author：Ys
 * Description:
 */
class EDURealTimeController {
  val eduDataService = new EDUDataService()
  val eduRecommendService = new EDURecommendService()
  def dispatch(data:DStream[Answer]): Unit = {
    //调用相应的Service模块

    eduDataService.dataAnalysis(data)
    eduRecommendService.dataAnalysis(data)

  }

}
